32.2.3 接收消息

当Rabbit设施出现时,所有bean都可以注解@RabbitListener来创建一个监听器端点。如果没有定义RabbitListenerContainerFactory,Spring Boot将自动配置一个默认的。如果定义MessageConverter beans,它将自动关联到默认的factory。

下面的组件创建一个someQueue队列上的监听器端点:

@Component
public class MyBean {

    @RabbitListener(queues = "someQueue")
    public void processMessage(String content) {
        // ...
    }

}

具体参考@EnableRabbit

如果需要创建多个RabbitListenerContainerFactory实例,或想覆盖默认实例,你可以使用Spring Boot提供的SimpleRabbitListenerContainerFactoryConfigurer,通过它可以使用跟自动配置实例相同的配置初始化SimpleRabbitListenerContainerFactory

例如,下面使用一个特殊的MessageConverter创建了另一个factory:

@Configuration
static class RabbitConfiguration {

    @Bean
    public SimpleRabbitListenerContainerFactory myFactory(
            SimpleRabbitListenerContainerFactoryConfigurer configurer) {
        SimpleRabbitListenerContainerFactory factory =
                new SimpleRabbitListenerContainerFactory();
        configurer.configure(factory, connectionFactory);
        factory.setMessageConverter(myMessageConverter());
        return factory;
    }

}

然后,你可以像下面那样在所有@RabbitListener注解方法中使用:

@Component
public class MyBean {

    @RabbitListener(queues = "someQueue", containerFactory="myFactory")
    public void processMessage(String content) {
        // ...
    }

}

你可以启动重试处理那些监听器抛出异常的情况,当重试次数达到限制时,该消息将被拒绝,要不被丢弃,要不路由到一个dead-letter交换器,如果broker这样配置的话,默认禁用重试。

重要 如果没启用重试,且监听器抛出异常,则Rabbit会不定期进行重试。你可以采用两种方式修改该行为:设置defaultRequeueRejected属性为false,这样就不会重试;或抛出一个AmqpRejectAndDontRequeueException异常表示该消息应该被拒绝,这是开启重试,且达到最大重试次数时使用的策略。